-define(APP, emqx_plugin_kafka).